package com.yuandian.bpm.bi.modules.quartz.util.redis;

import com.yuandian.bpm.bi.modules.quartz.util.QuartzUtil;
import lombok.extern.slf4j.Slf4j;

/**
 * 模块名称：redis监听通道数据处理（收到redis队列数据处理逻辑）
 */
@Slf4j
public class RedisReceiver {

	/**
	 * 向redis通道中发送数据
	 * @param param   删除/暂停任务：task|delete|任务ID
	 *
	 *                  说明：
	 *                  消息类型：固定字符串（task）
	 *                  任务类型：固定字符串（add、delete）
	 *                  任务ID：每个任务的自增长ID
	 * @return
	 */
    public void receiveMessage(String message) {
    	try {
	    	log.info("接收到redis数据：" + message);

	    	// 数据处理...
			QuartzUtil.operationalTasks(message);

    	} catch(Exception e) {
    		log.error("接收通道的数据，并处理，异常：", e);
    	}
    }
}
